package com.tul.exercise.base.thread.base;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class PonExecutors {

    /**
     * OLT 健康度调用线程池
     */
    private static ExecutorService oltHealthThreadPool;



    /**
     * 初始化线程池
     */
    static {
        // OLT健康度线程池
        oltHealthThreadPool = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue(), new NamedThreadFactory("OLT-HEALTH"));
    }

    /**
     * 获取OLT健康度任务线程池
     * @return
     */
    public static ExecutorService getOltHealthThreadPool() {
        return oltHealthThreadPool;
    }
}
